const ws = require('nodejs-websocket')
console.log("开始建立链接");

let users = [];
function boardcast(obj) {
  server.connections.forEach(function(conn) {
      conn.send(JSON.stringify(obj));
  })
}
let server = ws.createServer(function (conn) {
  conn.on("text", function (obj) {
    conn.send(JSON.stringify({
      type: 'robot',
      text: '你好，我是你的医学助理'
    }))
    conn.send(JSON.stringify({
      type: 'robot',
      text: '请详细描述你的病情，包括症状和持续时间'
    }))
    
    obj = JSON.parse(obj)
    console.log("收到的信息为", obj);
    boardcast({
      text: obj.text,
      type: obj.type
    });
    // conn.send(obj)
    // conn.send(`${a.text}（机器人）`)
  });
  conn.on("close", function (code, reason) {
    console.log("关闭连接")
  });
  conn.on("error", function (code, reason) {
    console.log("异常关闭")
  })
}).listen(8001);
console.log("链接建立完毕");